package utils

//
//import (
//	"bytes"
//	"context"
//	"encoding/json"
//	"log"
//	"strconv"
//	"strings"
//
//	"github.com/elastic/go-elasticsearch/v7"
//	"github.com/elastic/go-elasticsearch/v7/esapi"
//)
//
//func Es() {
//	cfg := elasticsearch.Config{
//		Addresses: []string{
//			"http://localhost:9200",
//		},
//		// ...
//	}
//	es, err := elasticsearch.NewClient(cfg)
//	if err != nil {
//		log.Println("es 连接失败")
//	}
//	log.Println("es 连接成功", es)
//}
//func Createtable(table string) {
//	for i, title := range []string{"Test One", "Test Two"} {
//		go func(i int, title string) {
//			// Build the request body.
//			data, err := json.Marshal(struct{ Title string }{Title: title})
//			if err != nil {
//				log.Fatalf("Error marshaling document: %s", err)
//			}
//
//			// Set up the request object.
//			req := esapi.IndexRequest{
//				Index:      "table",
//				DocumentID: strconv.Itoa(i + 1),
//				Body:       bytes.NewReader(data),
//				Refresh:    "true",
//			}
//			// Perform the request with the client.
//			res, err := req.Do(context.Background(), Es)
//			if err != nil {
//				log.Fatalf("Error getting response: %s", err)
//			}
//			defer res.Body.Close()
//
//			if res.IsError() {
//				log.Printf("[%s] Error indexing document ID=%d", res.Status(), i+1)
//			} else {
//				// Deserialize the response into a map.
//				var r map[string]interface{}
//				if err := json.NewDecoder(res.Body).Decode(&r); err != nil {
//					log.Printf("Error parsing the response body: %s", err)
//				} else {
//					// Print the response status and indexed document version.
//					log.Printf("[%s] %s; version=%d", res.Status(), r["result"], int(r["_version"].(float64)))
//				}
//			}
//		}(i, title)
//	}
//
//	log.Println(strings.Repeat("-", 37))
//}
